package com.xzr.demo.common;

import com.xzr.demo.mqserver.core.BasicProperties;

import java.io.IOException;

/**
 * @Author：徐志荣
 * @Date：2023/8/16 上午 10:26
 */
@FunctionalInterface
public interface Consumer {
    /**
     * Delivery的意思是“投递”，这个方法预期是每次服务器收到消息之后，来调用
     * 通过这个方法把消息推送给对应的消费者
     *
     * @return
     */
    void handleDelivery(String consumerTag, BasicProperties basicProperties, byte[] body) throws MqException, IOException;
}
